# -*- coding: utf-8 -*-
from airflow.providers.apache.sqoop.operators.sqoop import SqoopOperator
from utils.operators.mixins.condition_run_mixin import LatestOnlyMixin


class LatestOnlySqoopOperator(LatestOnlyMixin, SqoopOperator):
    """
    如果不是最新 dag_run 则直接跳过(状态变为 SKIPPED)
    仅跳过本 Operator，下游任务需要指定 trigger_rule 选择是否跳过或执行
    """
    pass
